//导入配置文件
const {dbconfig} = require('../config.js');
const mysql = require('mysql');
//创建数据库连接池
const pool = mysql.createPool(dbconfig);
let db = {}
//执行sql语句，并且把执行结果返回
db.q = function(sql,params){
	return new Promise((resolve,reject) =>{
		//从数据库连接池里边取出一个连接
		pool.getConnection((error,connection) =>{
			//如果获取连接对象失败，就把失败信息传递给error
			if(error){
				console.log("获取连接对象失败")
				reject(error);
				return;
			}
			//把连接对象归还到池子里
			connection.release();
			//取出的连接对象就传递给connection
			connection.query(sql,params,(error,result) =>{
				if(error){
					console.log("语句执行失败")
					reject(error);
				}
				resolve(result);
			})
		})
	})
}

module.exports = db;